package cn.virens.common.boot.rabbit.mqtt;

import cn.virens.common.util.exception.APIException;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.connection.CorrelationData;

public interface RabbitMqttService {

    void send(String routingKey, Object data) throws APIException;

    void send0(String routingKey, Message message) throws APIException;

    void send0(String routingKey, Message message, CorrelationData correlationData) throws APIException;

}
